package com.shopmall.ware.listener;

import com.shopmall.ware.service.WareSkuService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
//@RabbitListener(queues = "stock.release.stock.queue")
public class StockReleaseListener {

    @Autowired
    WareSkuService wareSkuService;

//    @RabbitHandler
//    public void handleStockLockedRelease(StockLockedTo to, Message message, Channel channel) throws IOException {
//
//        System.out.println("收到解锁库存的消息...");
//        try{
//            //当前消息是否被第二次及以后（重新）派发过来了。
////            Boolean redelivered = message.getMessageProperties().getRedelivered();
//            wareSkuService.unlockStock(to);
//            channel.basicAck(message.getMessageProperties().getDeliveryTag(),false);
//        }catch (Exception e){
//            channel.basicReject(message.getMessageProperties().getDeliveryTag(),true);
//        }
//
//    }
//
//    @RabbitHandler
//    public void handleOrderCloseRelease(OrderTo orderTo, Message message, Channel channel) throws IOException {
//        System.out.println("订单关闭准备解锁库存...");
//        try{
//            wareSkuService.unlockStock(orderTo);
//            channel.basicAck(message.getMessageProperties().getDeliveryTag(),false);
//        }catch (Exception e){
//            channel.basicReject(message.getMessageProperties().getDeliveryTag(),true);
//        }
//
//    }

}
